/*
 * Copyright (C) 2005 - 2013 MaNGOS <http://www.getmangos.com/>
 *
 * Copyright (C) 2008 - 2013 Trinity <http://www.trinitycore.org/>
 *
 * Copyright (C) 2010 - 2013 ProjectSkyfire <http://www.projectskyfire.org/>
 *
 * Copyright (C) 2011 - 2013 ArkCORE <http://www.arkania.net/>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
 */

#ifndef THREADING_H
#define THREADING_H

#include <ace/Thread.h>
#include <ace/TSS_T.h>
#include <ace/Atomic_Op.h>
#include <assert.h>

namespace ACE_Based {
class Runnable {
public:
	virtual ~Runnable() {
	}
	virtual void run() = 0;

	void incReference() {
		++m_refs;
	}
	void decReference() {
		if (!--m_refs)
			delete this;
	}
private:
	ACE_Atomic_Op<ACE_Thread_Mutex, long> m_refs;
};

enum Priority {
	Idle, Lowest, Low, Normal, High, Highest, Realtime,
};

#define MAXPRIORITYNUM (Realtime + 1)

class ThreadPriority {
public:
	ThreadPriority();
	int getPriority(Priority p) const;

private:
	int m_priority[MAXPRIORITYNUM];
};

class Thread {
public:
	Thread();
	explicit Thread(Runnable* instance);
	~Thread();

	bool start();
	bool wait();
	void destroy();

	void suspend();
	void resume();

	void setPriority(Priority type);

	static void Sleep(unsigned long msecs);
	static ACE_thread_t currentId();
	static ACE_hthread_t currentHandle();
	static Thread * current();

private:
	Thread(const Thread&);
	Thread& operator=(const Thread&);

	static ACE_THR_FUNC_RETURN ThreadTask(void * param);

	ACE_thread_t m_iThreadId;
	ACE_hthread_t m_hThreadHandle;
	Runnable * m_task;

	typedef ACE_TSS<Thread> ThreadStorage;
	//global object - container for Thread class representation of every thread
	static ThreadStorage m_ThreadStorage;
	//use this object to determine current OS thread priority values mapped to enum Priority{}
	static ThreadPriority m_TpEnum;
};
}
#endif
